package dataflow.example;

import org.apache.log4j.Logger;

public class Worker4 {
	
	static Logger log = Logger.getLogger(Worker4.class);
	
	public Integer run(Integer p){
		log.info("Worker4: running");
		try{
			log.info("Worker4: WAITING");
//			Thread.sleep(2000);
			log.info("Worker4: WAITING ended");
		}catch(Exception e){
			e.printStackTrace();
		}

		return 2;
	}
	
	public void setport1(Object o){
		log.info("Worker4: setting port1: " + (String)o);
	}
	
	public void setport2(Object o){
		log.info("Worker4: setting port2: " + (String)o);
	}
	
	public Object getport3(){
		return "Worker4";
	}
}
